package com.diao.flink.sql;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @author: chenzhidiao
 * @date: 2021/6/10 11:41
 * @description:
 * @version: 1.0
 */
public class DatahubConnector {


    public static final String DATAHUB_SOURCE_SQL="create table datahub_stream(" +
            " userid varchar, " +
            "knowledgeid varchar, " +
            "deptid varchar," +
            "createtime varchar " +
            ") with (" +
            " type='datahub', " +
            "endPoint='https://dh-cn-hangzhou.aliyuncs.com', " +
            "project='changcheng', " +
            "topic='log', " +
            "accessId='LTAI5tFcpmBa31yrWoMNp4Tc', " +
            "accessKey='mENImhLSE4z28vQSu9wvWeAhnRtyJE' );";

    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

    }
}
